package com.knight.hadoop.day04.mq.queue;

public class ConsumerTest implements Runnable {
	static Thread t1 = null;

	public static void main(String[] args) {
		t1 = new Thread(new ConsumerTest());
		t1.setDaemon(false);
		t1.start();
	}

	@Override
	public void run() {
		try {
			ConsumerTool consumer = new ConsumerTool();
			consumer.consumeMessage();
			while (ConsumerTool.isconnection) {
			}
		} catch (Exception e) {
		}

	}
}
